跳到主要内容

管理平台

docker安装kafka​

docker pull bitnami/zookeeper
docker pull bitnami/kafka:2.8.1
docker pull vimagick/cmak

创建zk​

docker run -itd --name zookeeper --restart=always --network=host   -p 2181:2181 -e ALLOW_ANONYMOUS_LOGIN=yes bitnami/zookeeper:latest

创建kafka​

  docker run -d --name kafka -p 9092:9092 --network=host --restart=always -e JMX_RMI_PORT=9998 -e JMX_PORT=9999 -e KAFKA_HEAP_OPTS="-Xmx256m -Xms64m" -e KAFKA_BROKER_ID=0 -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_CFG_ZOOKEEPER_CONNECT=172.16.7.237:2181 -e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://172.16.7.237:9092 -e TZ="Asia/Shanghai" -e KAFKA_JMX_OPTS="-Djava.rmi.server.hostname=172.16.7.237 -Dcom.sun.management.jmxremote.rmi.port=9998 -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false"  bitnami/kafka:2.8.1
  • 如果不指定 -Djava.rmi.server.hostname=10.253.51.157 或是会使用jmx连接kafka节点 host为localhost对应的地址。
  • 如果不指定 -Dcom.sun.management.jmxremote.rmi.port=9010会在 1024-65535中随机产生

创建管理平台​

docker run -d --name cmak --restart=always -p 9000:9000 -e ZK_HOSTS="172.16.7.237:2181" vimagick/cmak:latest

参考文章​

https://blog.csdn.net/player2135/article/details/111869191 https://blog.csdn.net/jm88621/article/details/100736645

注意​

  1. 要开启jmx。
  2. 点选Enable Active OffsetCache (Not recommended for large # of consumers)，Poll consumer information，Display Broker and Topic Size（就是要显示消费者，还有指定消费者组名称）